#lang racket/base

(provide (all-defined-out))

(struct observable (on-subscribe))
(struct subject observable (subscribers))
(struct subscriber (disposable next error completed))
(struct disposable ([disposed #:mutable] subdsps on-dispose))
(struct error (domain value))
